package main

import (
	"context"
	"github.com/beherochuling/beesoft_api/app/helper/net"
)

func main() {
	ctx := context.Background()

	// endpoint := "mqtt://localhost:1883"
	endpoint := "mqtt://111.229.207.234:1883"
	clientId := "abc"

	net.NewMqtt(ctx, endpoint).
		ClientId(clientId).
		Connect().
		Subscribe()
}
